package net.pws.common.simplemq;

public interface DataQueueProcessor {
    
    public DataPipe getDataPipe();
    
    public void stop();
    
}
